from celery import Celery

from app.core.config import settings

celery_app = Celery("worker", broker=f"redis://:{settings.REDIS_PASSWORD}@{settings.REDIS_HOST}:{settings.REDIS_PORT}/0")

celery_app.conf.task_routes = {"app.tasks.binance_spider_task.*": {"queue": "main-queue"},
                               "app.tasks.picker_task.*": {"queue": "main-queue"}}
